package com.yanggu.flink.datastream_api.test

import org.apache.flink.api.common.functions.MapFunction

/**
 * 验证无状态的Map函数, 一个输入得到一个输出
 */
class IncrementMapFunction extends MapFunction[Int, Int] {

    override def map(record: Int): Int = {
        record + 1
    }

}